package com.atguigu.preparedstatement.crud;

import com.atguigu.bean.Order;
import com.atguigu.util.JDBCUtils;
import org.junit.Test;

import java.lang.reflect.Field;
import java.sql.*;

/**
 * 针对于 order 表的通用的查询操作
 *
 * @author admin
 */
public class OrderForQuery {

    /**
     * 针对于表的字段名与类的属性名不相同的情况：
     * 1.必须声明 sql 时，使用类的属性名来命名字段的别名
     * 2.使用 ResultSetMateDate 时，需要使用 getColumnLabel() 来代替 getColumnName()，获取列的别名。
     * 说明：如果 sql 语句中没有给字段取别名，getColumnLabel() 获取的就是列名
     */
    @Test
    public void testOrderForQuery(){
        String sql = "select order_id orderId, order_name orderName, order_date orderDate from `order` where order_id = ?";
        Order order = orderForQuery(sql, 1);
        System.out.println(order);
    }

    /**
     * 通用的针对于 Order 表的查询操作
     */
    public Order orderForQuery(String sql, Object ...args) {

        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;

        try {
            // 1.获取连接
            connection = JDBCUtils.getConnection();

            // 2.预编译 sql 语句，返回 PreparedStatement 实例
            preparedStatement = connection.prepareStatement(sql);

            // 3.填充占位符
            for (int i = 0; i < args.length; i++) {
                preparedStatement.setObject(i + 1, args[i]);
            }

            // 4.执行，并返回结果集
            resultSet = preparedStatement.executeQuery();
            // 获取结果集的元数据
            ResultSetMetaData rsmd = resultSet.getMetaData();
            // 获取列数
            int columnCount = rsmd.getColumnCount();

            // 5.处理结果集
            if (resultSet.next()) {
                Order order = new Order();

                for (int i = 0; i < columnCount; i++) {
                    // 获取每个列的列值：通过 ResultSet
                    Object columnValue = resultSet.getObject(i + 1);

                    /*
                        通过 ResultSetMetaData
                        获取列的列名：getColumnName    --> 不推荐使用
                        获取列的别名：getColumnLabel
                     */
                    String columnLabel = rsmd.getColumnLabel(i + 1);

                    // 通过反射，将对象指定名 columnName 的属性赋值为指定的值 columnValue
                    Field field = Order.class.getDeclaredField(columnLabel);
                    field.setAccessible(true);
                    field.set(order, columnValue);
                }
                return order;
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            JDBCUtils.closeResource(connection, preparedStatement, resultSet);
        }

        return null;

    }

    @Test
    public void testQuery1() {

        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;

        try {
            // 1.获取连接
            connection = JDBCUtils.getConnection();

            // 2.预编译 sql 语句，返回 PreparedStatement 实例
            String sql = "select order_id, order_name, order_date from `order` where order_id = ?";
            preparedStatement = connection.prepareStatement(sql);

            // 3.填充占位符
            preparedStatement.setObject(1, 1);

            // 4.执行，并返回结果集
            resultSet = preparedStatement.executeQuery();

            // 5.处理结果集
            if (resultSet.next()) {
                int id = (int) resultSet.getObject(1);
                String name = (String) resultSet.getObject(2);
                Date date = (Date) resultSet.getObject(3);

                Order order = new Order(id, name, date);
                System.out.println(order);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 6.关闭资源
            JDBCUtils.closeResource(connection, preparedStatement, resultSet);
        }
    }
}
